package com.bungarus.busi;

import io.netty.channel.ChannelHandlerContext;

/**
 * Created by tang on 2018/11/30.
 */
public class GroupMessageProcessing extends BusiProcessing {
    private String groupId;
    private ChannelHandlerContext channelContext;

    public GroupMessageProcessing(String groupId, ChannelHandlerContext channelContext) {
        this.channelContext = channelContext;
        this.groupId = groupId;
    }

    /**
     * send message to all members in the group
     * @param o message to be sent
     * @throws BusiProcessingException
     */
    @Override
    public void doBusiness(Object o) throws BusiProcessingException {
        //get all members in group
        BusiProcessing.busiTaskPool.submit(() -> {

        });
    }
}
